package com.dangdang.annotation;

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 *
 * @author ligeng
 * 2019年6月27日
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface KafkaMqConsumer {
    /**
               *主题
     */
    String topic() default "";
    
    
    String bootStrapServices()  default "";
    
    String threads()  default "";
}
